package com.gitee.wordcount

import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironment}

object WordCountYarn {
  def main(args: Array[String]): Unit = {
    val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
    import org.apache.flink.api.scala._
    val lineData: DataStream[String] = env.readTextFile("file://D:/data/input/a.txt")




  }

}
